
package com.AdvancedDemos.Learn网络编程.CS架构.useTCP5改进4实现服务器收到信息时反馈给所有客户端;

import java.io.DataOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;

/**
 * 需求：客户端发送  在一起？   客户端接收数据
 */
public class Client {

    public static void main(String[] args) throws IOException {

        System.out.println("【客户端】开启！");
        //客户端socket
        Socket socket = new Socket("127.0.0.1", 8888);
        System.out.println("【客户端】连接成功");

        //开启线程专门用于接收数据
        Thread thread = new ClientReceiveThread(socket);
        thread.start();

        //发送数据
        //获取输出流
        Scanner sc = new Scanner(System.in);
        OutputStream outputStream = socket.getOutputStream();
        DataOutputStream dos = new DataOutputStream(outputStream);
        while (true) {
            System.out.println("【客户端】发送数据,请输入要发送的数据");
            String data = sc.nextLine();
            dos.writeUTF(data);

            //判断数据是否为结束信号，如果为结束信号，则跳出循环
            if ("#exit#".equals(data)) break;
        }

        System.out.println("【客户端】关闭资源");
        //关闭资源
        dos.close();
        //socket.close();
    }
}
